﻿using LJ.EventBus.Data;

namespace LJ.EventBus.HornedSerpent;

/// <summary>
/// 消息监听执行器
/// </summary>
public interface IEventBusMessageListener
{

    Task<bool> OnReceiveAsync(EventBusMessage message, CancellationToken cancellationToken);
}